package cn.doitedu.dao;

import cn.doitedu.pojo.CombineCondition;
import cn.doitedu.pojo.EventBean;
import cn.doitedu.pojo.LogBean;
import org.apache.flink.api.common.state.ListState;
import org.apache.flink.api.common.state.MapState;
import org.apache.flink.api.java.utils.ParameterTool;

public interface HistoryEventDao {
    void init(ParameterTool parameterTool, MapState<String, String> cacheState) throws Exception;

    void close() throws Exception;

    String queryEventStr(LogBean bean, CombineCondition combineCondition) throws Exception;
}
